package com.ww.springboot.boot.rxjava.rxjava2.my;

/**
 * 描述：
 *
 * @author 🧑 ‍wanwei
 * @since 2023-11-25 10:54
 */
public class ObservableMy {

    private EmitterMy emitter;

    public ObservableMy create(EmitterMy emitter) {
        this.emitter = emitter;
        return this;
    }

    public void subscribe(SubscriberMy<String> subscriber) {
        emitter.call(subscriber);
    }
}
